package com.huajx.core.model;

import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject;
import com.huajx.util.collection.CollUtil;
import com.huajx.util.convert.Convert;
import com.huajx.util.lang.Filter;

import java.util.Map;
import java.util.Map.Entry;

/**
 * 使用Mina解析出的HTTP请求对象
 *
 * @author xhye
 */
public class HttpRequestMessage {
    /**
     * HTTP请求的主要属性及内容
     */
    private Map<String, String[]> headers = null;
    private Map<String, String[]> paramenterMap;

    public Map<String, String[]> getHeaders() {
        return headers;
    }

    public Map<String, String[]> getParamenterMap(){
        return CollUtil.filter(headers, new Filter<Entry<String, String[]>>() {
            @Override
            public boolean accept(Entry<String, String[]> stringEntry) {

                return stringEntry.getKey().startsWith("@");
            }
        });
    }

    public void setHeaders(Map<String, String[]> headers) {
        this.headers = headers;
    }

    /**
     * 获取HTTP请求的Context信息
     */
    public String getContext() {
        String[] context = headers.get("Context");
        return context == null ? "" : context[0];
    }

    public String getMethod(){
        String[] method = headers.get("Method");
        return method == null ? "" : method[0];
    }

    /**
     * 根据属性名称获得属性值数组第一个值，用于在url中传递的参数
     *
     * @param name
     * @return
     */
    public String getParameter(String name) {
        String[] param = headers.get("@".concat(name));
//        if (param == null || param.length == 0) {
//            param = headers.get("@@@");
//            if (param == null || param.length == 0) {
//                return "";
//            } else {
//                try {
//                    JSONObject jso = JSON.parseObject(param[0]);
//                    return Convert.toStr(jso.getString(name), "");
//                } catch (Throwable e) {
//                    return "";
//                }
//            }
//        }else{
//            return param[0];
//        }
        return param == null || param.length == 0 ? "" : param[0];
    }

    /**
     * 根据属性名称获得属性值，用于在url中传递的参数
     *
     * @param name
     * @return
     */
    public String[] getParameters(String name) {
        String[] param = headers.get("@".concat(name));
        return param == null ? new String[]{} : param;
    }

    /**
     * 根据属性名称获得属性值，用于请求的特征参数
     *
     * @param name
     * @return
     */
    public String[] getHeader(String name) {
        return headers.get(name);
    }

    @Override
    public String toString() {
        StringBuilder str = new StringBuilder();

        for (Entry<String, String[]> e : headers.entrySet()) {
            str.append(e.getKey() + " : " + arrayToString(e.getValue(), ',') + "\n");
        }
        return str.toString();
    }

    /**
     * 静态方法，用来把一个字符串数组拼接成一个字符串
     *
     * @param s   要拼接的字符串数组
     * @param sep 数据元素之间的烦恼歌负
     * @return 拼接成的字符串
     */
    public static String arrayToString(String[] s, char sep) {
        if (s == null || s.length == 0) {
            return "";
        }
        StringBuffer buf = new StringBuffer();
        if (s != null) {
            for (int i = 0; i < s.length; i++) {
                if (i > 0) {
                    buf.append(sep);
                }
                buf.append(s[i]);
            }
        }
        return buf.toString();
    }
}
